package org.lpw.wormhole.queue;

import org.lpw.wormhole.element.Element;

/**
 * 本地队列处理器。用于处理本地队列消息。
 * 
 * @author lpw
 */
public interface LocalQueue
{
    /**
     * 添加队列处理器。
     * 
     * @param processor
     *            要添加的队列处理器。
     */
    public <T> void addProcessor(QueueProcessor processor);

    /**
     * 添加对象到本地队列。
     * 
     * @param element
     *            要添加的元素。
     */
    public void push(Element element);

    /**
     * 销毁环境。
     */
    public void destory();
}
